package com.zky.kafka.consumer;

import com.zky.kafka.domin.User;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

@Component

public class KafkaConsumer2 {
//    @KafkaListener(topics = "test-topic",groupId = "test-group2")
//    public void listen(User message) {
//        System.out.println("Consumer2 Received message: " + message);
//    }
}
